package com.northpool.stpclient.demo;

import com.northpool.stpclient.transfer.etl.IETLTransform;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class GeometryFilterTransform implements IETLTransform {
    Logger logger = LoggerFactory.getLogger(GeometryFilterTransform.class);
    public GeometryFilterTransform(String parm1) {

    }
    @Override
    public Object[] transform(Object[] item) {
        try {
            logger.error("hahaha");
            // item为数据库里的每一行数据
            for (int i = 0; i < item.length; i++) {
                // 遍历每一列数据
            }
            return item; // 返回行数据, 如果返回 null 则丢弃该行数据
        }catch (Exception ex) {
            throw new RuntimeException("中间算子异常：" + ex.getMessage());
        }
    }
}